package org.dromara.demo.controller.queue;

import cn.dev33.satoken.annotation.SaIgnore;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.common.core.domain.R;
import org.dromara.common.redis.utils.QueueUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;


/**
 * @Author 刘武贵
 * @Date 2024/8/15 22:00
 * @Description 功能描述：延迟队列 演示案例
 * 延迟队列 演示案例
 * <p>
 * 轻量级队列 重量级数据量 请使用 MQ
 * 例如: 创建订单30分钟后过期处理
 * <p>
 * 集群测试通过 同一个数据只会被消费一次 做好事务补偿
 * 集群测试流程 两台集群分别开启订阅 在其中一台发送数据 观察接收消息的规律
 *
 */
@SaIgnore
@Slf4j
@RequiredArgsConstructor
@RestController
@RequestMapping("/demo/queue/delayed")
public class DelayedQueueController {

    /**
     * 订阅队列
     *
     * @param queueName 队列名
     * @return R<Void> 操作结果对象，其中包含操作是否成功的信息
     */
    @GetMapping("/subscribe")
    public R<Void> subscribe(String queueName) {
        log.info("通道: {} 监听中......", queueName);
        // 项目初始化设置一次即可
        QueueUtils.subscribeBlockingQueue(queueName, (String orderNum) -> {
            // 观察接收时间
            // 设置队列的消息处理逻辑，并开启阻塞模式以确保消息被处理
            log.info("通道: {}, 收到数据: {}", queueName, orderNum);
            // 使用CompletableFuture来异步处理消息，避免阻塞主线程
            return CompletableFuture.runAsync(() -> {
                // 异步处理数据逻辑 不要在上方处理业务逻辑
                log.info("数据处理: {}", orderNum);
            });
        }, true);
        return R.ok("操作成功");
    }

    /**
     * 添加队列数据
     * 添加延迟队列对象到指定的队列中
     * 该方法接收队列名称、订单号和延迟时间作为参数，将一个包含订单信息的延迟队列对象添加到指定队列中
     * 主要用于实现延迟任务处理，比如订单的延迟处理、消息的延迟发送等场景
     *
     * @param queueName 队列名
     * @param orderNum  订单号，表示要处理的具体业务数据
     * @param time      延迟时间(秒)
     * @return 操作成功后返回R<Void>对象，其中包含操作结果信息
     */
    @GetMapping("/add")
    public R<Void> add(String queueName, String orderNum, Long time) {
        QueueUtils.addDelayedQueueObject(queueName, orderNum, time, TimeUnit.SECONDS);
        // 观察发送时间
        log.info("通道: {} , 发送数据: {}", queueName, orderNum);
        return R.ok("操作成功");
    }

    /**
     * 删除队列数据
     * 尝试从延迟队列中移除指定的元素
     *
     * @param queueName 队列名
     * @param orderNum  订单号，用于标识要删除的队列中的元素
     * @return R<Void>  返回操作结果的封装对象
     */
    @GetMapping("/remove")
    public R<Void> remove(String queueName, String orderNum) {
        // 尝试从队列中删除指定的延迟队列对象
        if (QueueUtils.removeDelayedQueueObject(queueName, orderNum)) {
            log.info("通道: {} , 删除数据: {}", queueName, orderNum);
        } else {
            return R.fail("操作失败");
        }
        return R.ok("操作成功");
    }

    /**
     * 销毁队列
     * 该方法用于销毁不再需要的延迟队列，以释放资源防止泄漏
     *
     * @param queueName 队列名 延迟队列的名称，需要唯一标识队列
     * @return R<Void> 操作结果，包含一个描述信息
     */
    @GetMapping("/destroy")
    public R<Void> destroy(String queueName) {
        // 用完了一定要销毁 否则会一直存在 销毁指定名称的延迟队列
        QueueUtils.destroyDelayedQueue(queueName);
        return R.ok("操作成功");
    }

}
